package now;

import java.io.IOException;
import java.net.Socket;

/**
 * 处理 Socket 对象，实现将消息从服务端发送到客户端
 * Created by zhangpeng on 2017/2/12.
 */

public class ChatSocket extends Thread {
    private Socket socket;

    public ChatSocket(Socket socket){
        this.socket=socket;
    }

    /**
     * 服务端发送数据到客户端
     * 就是通过将数据写出即可
     * @param s 要输出的文字
     */
    public void write(String s){
        try {
            //利用 socket 对象进行写出，即发送到客户端
            socket.getOutputStream().write(s.getBytes("UTF-8"));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        int count=1;
        //循环发送消息到客户端
        while (true){
        count++;
            write("from server"+count);
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
